/**
 * 抖音关注：程序员三丙
 * 知识星球：https://t.zsxq.com/j9b21
 */
package sanbing.example.dylike.infrastructure.queue.rpc;

import com.google.common.util.concurrent.ListenableFuture;
import sanbing.example.dylike.infrastructure.queue.QueueMsg;

import java.io.IOException;


public interface QueueHandler {

    ListenableFuture<QueueMsg> handle(QueueMsg request) throws IOException;

}
